package spring.cloud.tasks.client.item_task_processor;

import spring.cloud.tasks.client.ItemTaskWorker;

public class TaskItemsReAssignThread extends Thread {
    public TaskItemsReAssignThread(ItemTaskWorker itemTaskWorker) {
        super();
        this.itemTaskWorker = itemTaskWorker;
        this.workerId = itemTaskWorker.getWorkerId();
    }

    private ItemTaskWorker itemTaskWorker;
    private String workerId;

    @Override
    public void run() {
        //获取所有的任务 遍历所有的任务项
    }
}
